# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.sensors.date_time import DateTimeSensor

time_after_07_00 = DateTimeSensor(
    task_id='time_after_07_00',
    pool='unlimited_pool',
    target_time='{{ execution_date | add_month(1) | cst_ds }}T07:00:00+08:00',
    retries=0,
    mode='poke',
    execution_timeout=timedelta(hours=8),
    email=['yl_bigdata@yl-scm.com', 'time_sensor@yl-scm.com']
)
